/*
 * Copyright 2020-8-27 Baheal
 * @(#)RocketMqMessageListener.java
 */
package com.byyy.ccts.core.message.rocketmq.service;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;

/**
 * @author liyongbo
 * @version 1.0
 * @date 2020-8-27 15:51
 * @description： 消息处理
 */
public interface RocketMqMessageListener {
    boolean onMessage(List<MessageExt> messages,
                      ConsumeConcurrentlyContext Context);
}
